
#tasks--->broker--->worker
#Celery的创建步骤:
#1.先创建Celery对象
#2.通过celery对象来加载配置文件，就是设置broker

from celery import Celery
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'



app = Celery('celery_task')

#需要通过celery来设置 broker，即通过加载配置文件来设置
#配置文件就是  脚本名.文件名
app.config_from_object('celery_tasks.config')


#我们需要让celery自动检测任务,tssks可以检测多个任务
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

#worker  执行是通过指令，自动执行

#celery -A 脚本路径.celery的实例文件 worker -l info
#celery -A celery_tasks.main worker -l info
